package com.bujunjie.study.realtime.common.constant;

/**
 * <p>常量类</p>
 *
 * @author bu.junjie
 * @version 1.0.0
 * @createTime 2025/9/12 15:07
 */
public class FlinkConstant {

    /**
     * kafka broker地址
     */
    public static final String KAFKA_BROKERS = "192.168.112.10:9092,192.168.112.11:9092";

    /**
     * 数据库的 topic
     */
    public static final String TOPIC_DB = "topic_db";
    /**
     * 日志的 topic
     */
    public static final String TOPIC_LOG = "topic_log";

    /**
     * 数据库名
     */
    public static final String DATA_BASE = "gmall2024";


    /**
     * 数据库 host
     */
    public static final String MYSQL_HOST = "hadoop102";
    /**
     * 数据库 端口
     */
    public static final int MYSQL_PORT = 3306;
    /**
     * 数据库 用户名
     */
    public static final String MYSQL_USER_NAME = "root";
    /**
     * 数据库 密码
     */
    public static final String MYSQL_PASSWORD = "123456";
    /**
     * 维度表配置表名称
     */
    public static final String DIM_TABLE_NAME = "dim_table_process";


    /**
     * habse 命名空间
     */
    public static final String HBASE_NAMESPACE = "gmall2024";

    /**
     * mysql驱动
     */
    public static final String MYSQL_DRIVER = "com.mysql.cj.jdbc.Driver";
    /**
     * mysql连接
     */
    public static final String MYSQL_URL = "jdbc:mysql://hadoop102:3306?useSSL=false";
    /**
     * 常量值 1
     */
    public static final String ONE = "1";

    /**
     * 常量值 1
     */
    public static final String ZERO = "0";

    /**
     * 启动的 topic
     */
    public static final String TOPIC_DWD_TRAFFIC_START = "dwd_traffic_start";
    /**
     * 错误的 topic
     */
    public static final String TOPIC_DWD_TRAFFIC_ERR = "dwd_traffic_err";
    /**
     * 页面的 topic
     */
    public static final String TOPIC_DWD_TRAFFIC_PAGE = "dwd_traffic_page";

    /**
     * 动作的 topic
     */
    public static final String TOPIC_DWD_TRAFFIC_ACTION = "dwd_traffic_action";
    /**
     * 曝光的 topic
     */
    public static final String TOPIC_DWD_TRAFFIC_DISPLAY = "dwd_traffic_display";

    /**
     * 评论的 groupId
     */
    public static final String TOPIC_DWD_INTERACTION_COMMENT_INFO = "dwd_interaction_comment_info";

    /**
     * 增加购物车的 topic
     */
    public static final String TOPIC_DWD_TRADE_CART_ADD = "dwd_trade_cart_add";


    /**
     * 取消订单操作
     */
    public static final String TOPIC_DWD_TRADE_ORDER_CANCEL = "dwd_trade_order_cancel";

    /**
     * 订单明细表
     */
    public static final String TOPIC_DWD_TRADE_ORDER_DETAIL = "dwd_trade_order_detail";

    /**
     * 订单支付成功
     */
    public static final String TOPIC_DWD_TRADE_ORDER_PAYMENT_SUCCESS = "dwd_trade_order_payment_success";

    /**
     * 订单交易退款
     */
    public static final String TOPIC_DWD_TRADE_ORDER_REFUND = "dwd_trade_order_refund";

    /**
     * 订单交易退款成功
     */
    public static final String TOPIC_DWD_TRADE_REFUND_PAYMENT_SUCCESS = "dwd_trade_refund_payment_success";


    /**
     * doris 的数据库表名
     */
    public static final String DORIS_DATABASE = "gmall2024_realtime";

    public static final String DORIS_FE_NODES = "hadoop102:7030";

}
